#!/bin/bash
###编写人：zm
###编写日期：2024/07/10
###版本功能:实现Oracle跨库到hive的全量抽取 sqoop
###来源表 Oracle端 xm02用户下的 org_info SYS_USER_INFO表
###目标表 hive端 xm02ods数据库下的 org_info SYS_USER_INFO表
jdbc="jdbc:oracle:thin:@192.168.3.6:1521/orcl"
username="xm02"
password="123456"
table1="ORG_INFO"
table2="SYS_USER_INFO"
db1="xm02ods"
echo "------------------开始编写sqoop语句，进行机构信息表的数据全量抽取-------------"
sqoop import \
--hive-import \
--connect ${jdbc} \
--username ${username} \
--password ${password} \
--table ${table1} \
--hive-database ${db1} \
--fields-terminated-by ',' -m 1
echo $?
message=`hive -e "set hive.exec.mode.local.auto=true;select count(1) from ${db1}.${table1};"`
echo "------------------hive的ods层机构信息表数据条数为${message}条--------------------------------"
echo "-------------------hive的ods层机构信息表抽取完毕---------------------------------------------"
echo "---------------------------------分割线-------------------------"
echo "------------------开始编写sqoop语句，进行用户信息表的数据全量抽取-------------"
sqoop import \
--hive-import \
--connect ${jdbc} \
--username ${username} \
--password ${password} \
--table ${table2} \
--hive-database ${db1} \
--fields-terminated-by ',' -m 1
echo $?
message=`hive -e "set hive.exec.mode.local.auto=true;select count(1) from ${db1}.${table2};"`
echo "------------------hive的ods层用户信息表数据条数为${message}条--------------------------------"
echo "-------------------hive的ods层用户信息表抽取完毕---------------------------------------------"